package com.atzc.utils.filter;

import org.apache.flink.api.common.functions.FilterFunction;

/**
 * @author yhm
 * @create 2021-04-11 21:22
 */
public class ContainsDoubleOrFilterFunc implements FilterFunction<String> {
    String filterStr1 = "";
    String filterStr2 = "";

    public ContainsDoubleOrFilterFunc(String s1,String s2) {
        filterStr1 = s1;
        filterStr2 = s2;
    }

    @Override
    public boolean filter(String value) throws Exception {

        return value.contains(filterStr1) || value.contains(filterStr2);
    }
}
